package io.github.junxworks.junx.stream.extractor;


import io.github.junxworks.junx.event.EventBus;

/**
 * 数据抽取器
 *
 * @author 王兴
 * @date 2024/09/10
 */
public interface DataExtractor {
    void extract(ExtractContext context) throws Exception;

    void setEventBus(EventBus eventBus);

    void setFlowName(String flowName);

    boolean isDone();
}
